65809ffc860f4f19edf8ab30fded75bab11caf53,ambry-router/src/main/java/com.github.ambry.router/PutOperation.java,MetadataPutChunk,createPutRequest,#,1111
Before Change
@Override
protected PutRequest createPutRequest() {
return new PutRequest(NonBlockingRouter.correlationIdGenerator.incrementAndGet(), routerConfig.routerHostname,
chunkBlobId, blobProperties, ByteBuffer.wrap(userMetadata), new ByteBufferInputStream(buf.duplicate()),
buf.remaining(), BlobType.MetadataBlob);
}
}
After Change
@Override
protected PutRequest createPutRequest() {
return new PutRequest(NonBlockingRouter.correlationIdGenerator.incrementAndGet(), routerConfig.routerHostname,
chunkBlobId, blobProperties, ByteBuffer.wrap(userMetadata), buf.duplicate(), buf.remaining(),
BlobType.MetadataBlob);
}
}